#include "MsgUntils.h"
#include <stdio.h>

int getMsgQueue(char *pathName,int processId){
  key_t key = ftok(pathName,processId);
  if (key==-1)
  {
      perror("create key error");
      return -1;
  }

  int msgid= msgget(key,IPC_CREAT|0666);
  if (msgid==-1)
  {
      perror("get msgid error");
      return -1;
  }
  return msgid;
}
    //发消息
    int sendMsg(int mqId,Message* msg,int msgSize){
 int sendflg= msgsnd(mqId,msg,msgSize,0);
    if (sendflg==-1)
    {
        perror("send msg error");
        return -1;
    }

    return sendflg;

    }
    // 收消息
    int recvMsg(int mqId,Message* msg,int msgSize){
  int ret =  msgrcv(mqId,msg,msgSize,0,0);
    if (ret == -1)
    {
        perror("recv msg error: ");
        return -1;
    }
    return ret;
    }